package cn.itcast.mq.config;

import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.QueueBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 消费者启动的时候可以通过配置类创建队列、交换机,并将二者绑定
 */
//@Configuration
public class CommonConfig {
    /**
     * 创建持久化交换机
     *
     * @return
     */
    @Bean
    public DirectExchange directExchange() {
        return new DirectExchange("simple.direct", true/*交换机是否持久化*/, false/*当没有queue与其绑定时是否自动删除*/);
    }

    /**
     * 创建持久化队列
     *
     * @return
     */
    @Bean
    public Queue simpleQueue() {
        return QueueBuilder.durable("simple.queue"/*指定队列名同时持久化*/).build();
    }
}
